package cloudy.trident.tools;

import org.apache.storm.trident.operation.BaseFunction;
import org.apache.storm.trident.operation.TridentCollector;
import org.apache.storm.trident.tuple.TridentTuple;

/**
 * @Name cloudy.trident.tools.Print
 * @Description
 * @Author Elwyn
 * @Version 2017/9/30
 * @Copyright 上海云辰信息科技有限公司
 **/
public class Print extends BaseFunction {
	@Override
	public void execute(TridentTuple tridentTuple, TridentCollector tridentCollector) {
		if (!tridentTuple.isEmpty()){
			String string = tridentTuple.getString(0);
			System.err.println(string);
		}
	}
}
